package com.xiangxiao.rpan.data.channel;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;

/**
 * @Projectname: rpan-data
 * @Author: xiangxiao
 * @Email: 573768011@qq.com
 * @Data:2024/5/31 0:56
 */
public interface RpanDataStreams {
  /**
   * 发消息的通道名称
   */
  String RAPN_OUTPUT = "rpan-output";

  /**
   * 消息的订阅通道名称
   */
  String RAPN_INPUT = "rpan-input";

  /**
   * 发消息的通道
   *
   * @return
   */
  @Output(RAPN_OUTPUT)
  MessageChannel rpanDataOutput();

  /**
   * 收消息的通道
   *
   * @return
   */
  @Input(RAPN_INPUT)
  SubscribableChannel rpanDataInput();
}
